package com.lty.protocol.tcp.handler;

import io.netty.channel.ChannelInboundHandlerAdapter;
import lombok.extern.slf4j.Slf4j;


/**
 * @ClassName EchoHandler
 * @Description tcp客户端业务逻辑处理handler
 * @Author Administrator
 */
@Slf4j
public class EchoHandler extends ChannelInboundHandlerAdapter {

    // //连接成功后发送消息测试
    // @Override
    // public void channelActive(ChannelHandlerContext ctx) throws Exception {
    //     SysLogin sysLogin = new SysLogin();
    //     sysLogin.setUserId("fangjin");
    //     sysLogin.setUserName("方进");
    //     sysLogin.setPassword("123456");
    //     DTObject dtObject = new DTObject();
    //     dtObject.setClassName(sysLogin.getClass().getName());
    //     dtObject.setObject(new ObjectMapper().writeValueAsBytes(sysLogin));
    //     TcpProtocol tcpProtocol = new TcpProtocol();
    //     byte [] objectBytes=new ObjectMapper().writeValueAsBytes(dtObject);
    //     tcpProtocol.setLen(objectBytes.length);
    //     tcpProtocol.setData(objectBytes);
    //     ctx.write(tcpProtocol);
    //     ctx.flush();
    // }
    //
    // @Override
    // public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    //     if (msg instanceof byte[]) {
    //         log.debug("解码后的字节码：" + new String((byte[]) msg, "UTF-8"));
    //     }
    // }
}